package com.celeritymq.session;

import java.net.SocketAddress;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;

public class SessionContainerImpl implements SessionContainer {
	/**
	 * 
	 */
	private static final long serialVersionUID = -2444934621446527688L;
	private ConcurrentMap<String, Map<SocketAddress, CeleritySession>> topicSessionMap = new ConcurrentHashMap<String, Map<SocketAddress, CeleritySession>>();
	private ConcurrentMap<String, Map<SocketAddress, CeleritySession>> queueSessionMap = new ConcurrentHashMap<String, Map<SocketAddress, CeleritySession>>();

	@Override
	public boolean register(CeleritySession session) {
		if (session instanceof CelerityTopicSession) {

		}
		return false;
	}

	@Override
	public boolean unRegister(CeleritySession session) {
		// TODO Auto-generated method stub
		return false;
	}

}
